const { connect, connectPool } = require('./config')

// let query = (sql, values) => {
//     const connectDB = connect(values);
//     connectDB.connect((err)=>{
//         if(err){
//             reject({ code: 500, message: err.message })
//         }else{
//             return new Promise((resolve, reject) => {
//                 connectDB.query(sql, (err, rows) => {
//                     if (err) {
//                         reject({ code: 500, message: err.message })
//                     } else {
//                         resolve({ code: 200, data: rows })
//                     }
//                 })
//                 // connection.destroy();
//                 connectDB.end((err)=>{
//                     if(err){
//                         reject({ code: 500, message: err.message })
//                     }
//                 })
//             })
//         }
//     })
// }


let query = (sql, values) => {
    return new Promise((resolve, reject) => {
        connectPool(values).getConnection((err, connection) => {
            if (err) {
                reject({ code: 500, message: err })
            } else {
                connection.query(sql, (err, rows) => {
                    if (err) {
                        reject({ code: 500, message: err.message })
                    } else {
                        resolve({ code: 200, data: rows })
                    }
                    connection.release();
                })
            }
        })
    })
}

module.exports = {
    query: query
}